<?php

/**
 * Источник данных
 *
 * @author goorus, morph
 * @Service("dataSource")
 */
class Data_Source
{
    /**
     * Собственная конфигурация источника данных
     *
     * @var array
     */
    protected $config;

    /**
     * Текущий драйвер источника данных
     *
     * @var Data_Driver_Abstract
     */
    protected $driver;

    /**
     * Фильтры
     *
     * @var array
     */
    protected $filters = array();

    /**
     * Название источника данных
     *
     * @var string
     */
    protected $name;

    /**
     * Текущий запрос
     *
     * @var Query
     */
    private $query;

    /**
     * Зарегистирированные таблицы
     *
     * @var array
     */
    protected $registeredTables = array();

    /**
     * Результат последнего выполненного запроса
     *
     * @var Query_Result
     */
    private $result;

    /**
     * Применить фильтры
     *
     * @param Query_Abstract $query
     */
    public function applyFilters(Query_Abstract $query)
    {
        foreach ($this->filters as $filter) {
            $query = $filter->filter($query);
            if (!$query) {
                break;
            }
        }
        return $query;
    }

    /**
     * Проверяет доступность источника данных
     *
     * @return boolean
     */
    public function available()
    {
        return $this->driver()->available();
    }

    /**
     * Получить (инициализировать) драйвер
     *
     * @return Data_Driver_Abstract
     */
    public function driver()
    {
        if (!$this->driver) {
            $serviceLocator = IcEngine::serviceLocator();
            $dataSourceManager = $serviceLocator->getService(
                'dataSourceManager'
            );
            $dataSourceManager->initDataDriver($this);
        }
        return $this->driver;
    }

    /**
     * Выполняет запрос к источнику данных
     *
     * @param Query_Abstract $query Запрос
     * @param Query_Options $options Опции запроса
     * @throws Exception
     * @return Data_Source_Abstract
     */
    public function execute(Query_Abstract $query, $options = null)
    {
        $options = $options ? : new Query_Options();
        $query = $this->applyFilters($query);
        if (!$query) {
            return $this;
        }
        $this->setQuery($query);
        try {
            $result = $this->driver()->execute($query, $options);
        } catch (Exception $e) {
            throw new ErrorException('query: ' . $this->query->translate(), 0, 1, __FILE__, __LINE__, $e);
        }
        if ($result->touchedRows()) {
            $this->notifySignal($query, $result);
        }
        $this->setResult($result);
        return $this;
    }

    /**
     * Получить собственную конфигурацию источника данных
     *
     * @return array
     */
    public function getConfig()
    {
        return $this->config;
    }

    /**
     * Получить текущий драйвер
     *
     * @return Data_Driver_Abstract
     */
    public function getDataDriver()
    {
        return $this->driver;
    }

    /**
     * Получить фильтры
     *
     * @return array
     */
    public function getFilters()
    {
        return $this->filters;
    }

    /**
     * Получить название источника
     *
     * @return string
     */
    public function getName()
    {
        return $this->name;
    }

    /**
     * Возвращает запрос
     *
     * @params null|string $translator
     *        Ожидаемый вид запроса.
     *        Если необходим объект запроса, ничего не указывется (по умолчанию).
     *        Если указать транслятор, то результом будет результат трансляции.
     * @return Query|mixed
     */
    public function getQuery($translator = null)
    {
        return $translator
            ? $this->query->translate($translator) : $this->query;
    }

    /**
     * Получить результат последнего выполненного запроса
     *
     * @return Query_Result
     */
    public function getResult()
    {
        return $this->result;
    }

    /**
     * Наполнить схему данных через источник данных
     *
     * @param Data_Scheme $scheme
     * @return Data_Scheme
     */
    public function getScheme(Data_Scheme $scheme)
    {
        $scheme->setDataSource($this);
        $serviceLocator = IcEngine::serviceLocator();
        $dataSchemeManager = $serviceLocator->getService('dataSchemeManager');
        return $dataSchemeManager->getScheme($scheme);
    }

    /**
     * Нотификация сигнала
     *
     * @param Query_Abstract $query
     * @param Query_Result $result
     */
    public function notifySignal(Query_Abstract $query, Query_Result $result)
    {
        $tableName = $query->tableName();
        $queryType = $query->type();
        $signalName = 'Data_Source_' . ucfirst(strtolower($queryType));
        $isTableRegistered = in_array($tableName, $this->registeredTables);
        if ($queryType != Query::SELECT || $isTableRegistered) {
            $serviceLocator = IcEngine::serviceLocator();
            $eventManager = $serviceLocator->getService('eventManager');
            $signal = $eventManager->getSignal($signalName);
            $signal->setData(array(
                'result' => $result,
                'table' => $tableName
            ));
            $signal->notify();
        }
    }

    /**
     * Зарегистировать таблицу
     *
     * @param mixed $table
     */
    public function registerTable($table)
    {
        foreach ((array)$table as $tableName) {
            $this->registeredTables[] = $tableName;
        }
    }

    /**
     * Изменить собственную конфигурация источника данных
     *
     * @param array $config
     */
    public function setConfig($config)
    {
        $this->config = $config;
    }

    /**
     * Устанавливает драйвер
     *
     * @param Data_Driver_Abstract $driver
     * @return Data_Source
     */
    public function setDataDriver(Data_Driver_Abstract $driver)
    {
        $this->driver = $driver;
        return $this;
    }

    /**
     *
     * @param type $filters
     * @return Data_Source
     */
    public function setFilters($filters)
    {
        $this->filters = $filters;
        return $this;
    }

    /**
     * Изменить название источника
     *
     * @param string $name
     */
    public function setName($name)
    {
        $this->name = $name;
    }

    /**
     * Устанавливает запрос
     *
     * @param Query_Abstract $query
     * @return Data_Source
     */
    public function setQuery(Query_Abstract $query)
    {
        $this->query = $query;
        return $this;
    }

    /**
     * Устанавливает результат запроса.
     *
     * @param Query_Result $result
     * @return Data_Source
     */
    public function setResult(Query_Result $result)
    {
        $this->result = $result;
        return $this;
    }
}